﻿import os
import sys
from db import odbc
import basic

__dir__ = os.path.dirname(os.path.abspath(__file__))
path_error = os.path.join(__dir__, "odbcmysql.log")
sys.stderr = open(path_error, 'a')

#В функцию update передается по умолчанию значение 300.000
cache_default=300000

#Если в командной строке задан параметр, 
if len(sys.argv)==2:
	#то он используется в качестве аргумента по умолчанию функции update
	cache_default=sys.argv[1]
	
def update_old(cache=cache_default):
	"This function updates data in mysql from ODBC"
	#print (odbcmysql.update_old.__doc__)
	#beginning of function suite
	basic.delete()
	odbc.connect()
	basic.extract()
	array=basic.fetch(cache)
	while array!=None:
		basic.insert(basic.transform(array))
		array=basic.fetch(cache)
	odbc.disconnect()
	
def update(cache=cache_default):
	"This function updates data in mysql from ODBC"
	#print (odbcmysql.update.__doc__)
	#beginning of function suite
	basic.delete()
	odbc.connect()
	basic.extract()
	array=basic.fetch(cache)
	while array!=None:
		basic.insert(array)
		array=basic.fetch(cache)
	odbc.disconnect()


sys.stderr.close()
sys.stderr = sys.__stderr__